<?php
/**
 * Clase CRUD
 *
 * Esta clase facilita la capa de acceso PDO a la base de datos
 *
 * @author Ricard Forner
 * @version 0.1.0
 * @package appmedia
 *
 * @link http://www.phpro.org/classes/PDO-CRUD.html
 */
class crud {

    private $db;

    /**
     * Set variables
     */
    public function __set($name, $value) {
        switch($name) {
            case 'username':
            $this->username = $value;
            break;

            case 'password':
            $this->password = $value;
            break;

            case 'dsn':
            $this->dsn = $value;
            break;

            default:
            throw new Exception("$name is invalid");
        }
    }

    /**
     * @check variables have default value
     */
    public function __isset($name) {
        switch($name) {
            case 'username':
            $this->username = null;
            break;

            case 'password':
            $this->password = null;
            break;
        }
    }

        /**
         * @Connect to the database and set the error mode to Exception
		 *
         * @Throws PDOException on failure
         */
        public function conn() {
            isset($this->username);
            isset($this->password);
            if (!$this->db instanceof PDO) {
                $this->db = new PDO($this->dsn, $this->username, $this->password);
                $this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            }
        }

		public function dbCreate($sql) {
			$this->rawSelect($sql);
		}

        /***
         * @select values from table
         * @access public
         * @param string $table The name of the table
         * @param string $fieldname
         * @param string $id
		 *
         * @return array on success or throw PDOException on failure
         */
        public function dbSelect($table, $fieldname=null, $id=null) {
            $this->conn();
            $sql = "SELECT * FROM `$table` WHERE `$fieldname`=:id";
            $stmt = $this->db->prepare($sql);
            $stmt->bindParam(':id', $id);
            $stmt->execute();
            return $stmt->fetchAll(PDO::FETCH_ASSOC);
        }


        /**
         * @execute a raw query
         * @access public
         * @param string $sql
         *
         * @return array
         */
        public function rawSelect($sql) {
            $this->conn();
            return $this->db->query($sql);
        }

        /**
         * @run a raw query
         * @param string The query to run
         */
        public function rawQuery($sql) {
            $this->conn();
            $this->db->query($sql);
        }


        /**
         * @Insert a value into a table
         * @acces public
         * @param string $table
         * @param array $values
         *
         * @return int The last Insert Id on success or throw PDOexeption on failure
         */
        public function dbInsert($table, $values) {
            $this->conn();
            /*** snarg the field names from the first array member ***/
            $fieldnames = array_keys($values[0]);
            /*** now build the query ***/
            $size = sizeof($fieldnames);
            $i = 1;
            $sql = "INSERT INTO $table";
            /*** set the field names ***/
            $fields = '( ' . implode(' ,', $fieldnames) . ' )';
            /*** set the placeholders ***/
            $bound = '(:' . implode(', :', $fieldnames) . ' )';
            /*** put the query together ***/
            $sql .= $fields.' VALUES '.$bound;

            /*** prepare and execute ***/
            $stmt = $this->db->prepare($sql);
            foreach($values as $vals)
            {
                $stmt->execute($vals);
            }
        }

        /**
         * @Update a value in a table
         * @access public
         * @param string $table
         * @param string $fieldname, The field to be updated
         * @param string or array $value The new value
         * @param string $pk The primary key
         * @param string $id The id
         *
         * @throws PDOException on failure
         */
        public function dbUpdate($table, $fieldname, $value, $pk, $id) {
            $this->conn();
			if (is_array($value)) {
				$fieldnames = array_keys($value);
				$fieldsUpd = "";
				foreach($fieldnames as $key) {
					$fieldsUpd.= "`$key`='{$value[$key]}',";
				}
				$fieldsUpd = substr($fieldsUpd,0,-1);
				$sql = "UPDATE `$table` SET $fieldsUpd WHERE `$pk` = :id";
			} else {
				$sql = "UPDATE `$table` SET `$fieldname`='{$value}' WHERE `$pk` = :id";
			}
            $stmt = $this->db->prepare($sql);
            $stmt->bindParam(':id', $id, PDO::PARAM_STR);
            $stmt->execute();
        }


        /**
         * @Delete a record from a table
         * @access public
         * @param string $table
         * @param string $fieldname
         * @param string $id
         *
         * @throws PDOexception on failure
         */
        public function dbDelete($table, $fieldname, $id) {
            $this->conn();
            $sql = "DELETE FROM `$table` WHERE `$fieldname` = :id";
            $stmt = $this->db->prepare($sql);
            $stmt->bindParam(':id', $id, PDO::PARAM_STR);
            $stmt->execute();
        }
    } /*** end of class ***/

?>